package producer_consumer;

import java.util.concurrent.BlockingDeque;
import java.util.concurrent.LinkedBlockingDeque;

public class BlockQueueDemo {

    private final BlockingDeque<Task> queue;

    /**
     * 初始化隊列
     * @param cap 容量
     */
    public BlockQueueDemo(int cap) {
        this.queue = new LinkedBlockingDeque<Task>(cap);
    }

    private class ProducerImpl implements Producer{

        @Override
        public void producer() {

        }

    }


}
